42231e1ab8d674d68dfb3956d5616dc67ac8d4df,ambry-tools/src/main/java/com.github.ambry.tools/admin/DumpData.java,DumpData,dumpActiveBlobsFromIndex,#File#ArrayList#boolean#,405
Before Change
public void dumpActiveBlobsFromIndex(File indexFileToDump, ArrayList<String> blobList, boolean excludeMiscLogging) {
ConcurrentHashMap<String, String> blobIdToBlobMessageMap = new ConcurrentHashMap<String, String>();
if (!excludeMiscLogging) {
logOutput("Dumping index " + indexFileToDump);
}
ActiveBlobStats activeBlobStats = new ActiveBlobStats();
long totalKeysProcessed =
dumpActiveBlobsFromIndex(indexFileToDump, blobList, blobIdToBlobMessageMap, excludeMiscLogging,
activeBlobStats);
for (String blobId : blobIdToBlobMessageMap.keySet()) {
logOutput(blobId + " : " + blobIdToBlobMessageMap.get(blobId));
}
if (!excludeMiscLogging) {
logOutput("Total Keys processed for index file " + indexFileToDump + " " + totalKeysProcessed);
logOutput(
"Total Put Records for index file " + indexFileToDump + " " + activeBlobStats.getTotalPutRecords().get());
logOutput("Total Delete Records for index file " + indexFileToDump + " " + activeBlobStats.getTotalDeleteRecords()
.get());
logOutput("Total Active Records for index file " + indexFileToDump + " " + blobIdToBlobMessageMap.size());
logOutput("Total Duplicate Put Records for index file " + indexFileToDump + " " + activeBlobStats
.getTotalDuplicatePutRecords().get());
logOutput("Total Delete before Put Or duplicate Delete Records for index file " + indexFileToDump + " "
+ activeBlobStats.getTotalDeleteBeforePutOrDuplicateDeleteRecords().get());
}
}
After Change
*/
public void dumpActiveBlobsFromIndex(File indexFileToDump, ArrayList<String> blobList) {
ConcurrentHashMap<String, String> blobIdToBlobMessageMap = new ConcurrentHashMap<>();
logger.trace("Dumping index " + indexFileToDump);
ActiveBlobStats activeBlobStats = new ActiveBlobStats();
long totalKeysProcessed =
dumpActiveBlobsFromIndex(indexFileToDump, blobList, blobIdToBlobMessageMap, activeBlobStats);
for (String blobId : blobIdToBlobMessageMap.keySet()) {
logger.info(blobId + " : " + blobIdToBlobMessageMap.get(blobId));
}
logger.trace("Total Keys processed for index file " + indexFileToDump + " " + totalKeysProcessed);
logger.trace(
"Total Put Records for index file " + indexFileToDump + " " + activeBlobStats.getTotalPutRecords().get(),
LogLevel.DEBUG);
logger.trace(
"Total Delete Records for index file " + indexFileToDump + " " + activeBlobStats.getTotalDeleteRecords().get(),
LogLevel.DEBUG);
logger.trace("Total Active Records for index file " + indexFileToDump + " " + blobIdToBlobMessageMap.size());
logger.trace("Total Duplicate Put Records for index file " + indexFileToDump + " "
+ activeBlobStats.getTotalDuplicatePutRecords().get());
logger.trace("Total Delete before Put Or duplicate Delete Records for index file " + indexFileToDump + " "
+ activeBlobStats.getTotalDeleteBeforePutOrDuplicateDeleteRecords().get());
}
/**